package cn.gwm.flink.streaming.strategy.multidimension;

import com.alibaba.fastjson.JSONObject;
import org.apache.flink.api.common.state.MapState;
import redis.clients.jedis.JedisCluster;

import java.io.Serializable;

/**
 * @author : GW00280745
 * @date : 2022/12/19 13:14
 * @description : 样本库匹配接口
 * 匹配顺序 车辆vin、时间、地点、电流、起点soc、温度、目标soc(option)
 */
public class MultiDimensionTimePredict implements Serializable {
    MultiDimensionTimePredictObc mdt= new MultiDimensionTimePredictObc();
    public String timeV1(MapState<String, String> latestEstimateState,
                       JSONObject line,
                       String chargeGroup,
                       JedisCluster socIntervalJedis,boolean firstTime) {
        return  mdt.timeV1(latestEstimateState,line,chargeGroup,socIntervalJedis,firstTime);
    }
}
